package com.iot08.admin.service;

import com.iot08.common.config.redis.RedisService;
import com.iot08.common.constant.ConstCacheField;
import com.iot08.common.utils.StringUtil;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @version 1.0
 * @Description: kafka推送相关业务处理
 * @time: 2020/11/27 8:44
 * @author: Rock
 */
@Service
public class KafkaService {

//    @Resource
//    private RedisService redisService;
//    //@Resource
//    //private KafkaProducer kafkaProducer;
//
//    /**
//     * @param imei
//     * @param type
//     * @time: 2020/11/28 11:39
//     * @author: Rock
//     * @version 1.0
//     */
//    /*public void send(String imei, int type){
//        JSONObject data = new JSONObject();
//        data.put("type", type);
//        data.put("ident", 666666);
//        kafkaProducer.send(imei, data.toJSONString());
//    }*/
//
//    /**
//     * @param imei
//     * @param data
//     * @time: 2020/11/27 9:05
//     * @author: Rock
//     * @version 1.0
//     */
//    public void emitDeviceDemand(String imei, int type) {
//        if (redisService.exists(imei)) {
//            String value = redisService.hget(imei, ConstCacheField.V);
//            redisService.del(imei);
//            if (StringUtil.isNotBlank(value)) {
//                redisService.hset(imei, ConstCacheField.V, value);
//            } else {
//                redisService.hset(imei, ConstCacheField.V, "20000");
//            }
//            redisService.hset(imei, "contacts", "{\"last\":0,\"ident\":1616,\"contact\":[],\"index\":0,\"type\":16}");
//            redisService.hset(imei, "contactsSync", "1");
//            redisService.hset(imei, "alarms", "{\"ident\":3030,\"alarm\":[],\"type\":30}");
//            redisService.hset(imei, "alarmsSync", "1");
//            redisService.hset(imei, "disBan", "{\"disturb\": [], \"ident\": 2828, \"type\": 28}");
//            redisService.hset(imei, "disBanSync", "1");
//            redisService.hset(imei, "onlineStatus", "0");
//        }
//        //kafka下发
//        //send(imei, type);
//    }
}
